# -*- coding: utf-8 -*-
from datetime import timedelta

from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor
from jms.time_sensor.time_after_03_00 import time_after_03_00
jms_dwd__dwd_tab_barscan_sitesend_base_hi_02 = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_dwd__dwd_tab_barscan_sitesend_base_hi_02",
    filepath='/dw/hive/jms_dwd.db/external/dwd_tab_barscan_sitesend_base_hi/dt={{ execution_date | date_add(1) | cst_ds }}-02',
    #execution_timeout=timedelta(hours=3)
    #excel平均时长:0
    #execution_timeout = timedelta(minutes=15)
    #excel平均时长:0
    execution_timeout = timedelta(minutes=30),
    email=['guoruiling@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=2,
)
jms_dwd__dwd_tab_barscan_sitesend_base_hi_02 << time_after_03_00